package cn.itcast.tags.models.rule

import cn.itcast.tags.models.BasicModel
import cn.itcast.tags.tools.TagTools
import org.apache.spark.sql.{DataFrame, Row, SparkSession}

/**
 * 用户政治面貌标签
 */
class PoliticalModel extends BasicModel{
  override def doTag(businessDF: DataFrame, tagDF: DataFrame): DataFrame = {

    val modelDF: DataFrame = TagTools.ruleMatchTag(businessDF, "politicalface", tagDF)
    //modelDF.show(100,false)

    modelDF

  }
}

object PoliticalModel{
  def main(args: Array[String]): Unit = {
    val tagModel = new PoliticalModel
    tagModel.executeModel(328L)
  }
}
